# 批处理配置
BATCH_CONFIG = {
    'size': 10,
    'timeout': 10.0
}

# Kafka配置
KAFKA_CONFIG = {
    "pathway_producer": {
        "bootstrap.servers": "180.76.250.147:19092",  # Kafka broker 地址
        # "security.protocol": "PLAINTEXT",  # 安全协议
    },
    "pathway_consumer": {
        "bootstrap.servers": "180.76.250.147:19092",  # Kafka broker 地址
        "security.protocol": "PLAINTEXT",  # 安全协议
        "group.id": "pathway-consumer-group",  # 消费者组ID
    }
}
TOPIC_CONFIG = {
    "default": {
        "topic": "temp4"
    }
}

# 数据库配置
MYSQL_DATABASES = {
    "xxx": {
        "type": "mysql",
        'user': 'medpeer',
        'password': 'medpeer',
        'host': '192.168.1.245',
        'port': 3306,
        'database': 'raw_data',
        "charset": "utf8mb4"
    },
    "default": {
        "type": "mysql",
        'user': 'root',
        'password': 'Btlg2002',
        'host': '192.168.1.15',
        'port': 3306,
        'database': 'info',
        "charset": "utf8mb4"
    },
    "default1": {
        "type": "mysql",
        'user': 'root',
        'password': 'Btlg2002',
        'host': '192.168.1.15',
        'port': 3306,
        'database': 'nfsc',
        "charset": "utf8mb4"
    },
    "default2": {
        "type": "mysql",
        'user': 'root',
        'password': 'Btlg2002',
        'host': '192.168.1.15',
        'port': 3306,
        'database': 'test',
        "charset": "utf8mb4"
    },
}

MONGODB_DATABASES = {
    "default": {
        "type": "mongodb",
        'user': 'medpeer',
        'password': 'medpeer',
        'auth_source': 'admin',  # 认证数据库（必须与用户创建库一致）
        'host': '192.168.1.245',
        'port': 27017,
        'database': 'raw_data',
        "charset": "utf8mb4"
    },
}
REDIS_DATABASES = {
    "default": {
        "type": "redis",
        'password': 'medpeer',
        'host': '101.200.62.36',
        'port': 6379,
        'database': 1,
    }
}
# ElasticSearch数据库连接
# ELASTIC_CONNECTION = {
#     "default": {
#         # 连接标识
#         "sign": "default",
#         # 服务器地址
#         'host': 'http://192.168.1.245:9200',
#         # 账号
#         "user": "elastic",
#         # 密码
#         "password": "medpeer",
#         # 连接协议
#         "scheme": "http",
#         # 服务器端口
#         'port': 9200,
#         # 超时时间（秒）
#         "timeout": 30,
#         # 错误重试次数
#         "max_retries": 3,
#         # 超时是否重试
#         "retry_on_timeout": True,
#     },
# }
ELASTIC_CONNECTION = [
    {
        # 连接标识
        "sign": "default",
        # 服务器地址
        'host': ['192.168.1.245'],
        # 账号
        "user": "elastic",
        # 密码
        "password": "medpeer",
        # 连接协议
        "scheme": "http",
        # 服务器端口
        'port': 9200,
        # 超时时间（秒）
        "timeout": 30,
        # 错误重试次数
        "max_retries": 3,
        # 超时是否重试
        "retry_on_timeout": True,
    },
]